package com.ideal.lx_mss.service;



import com.ideal.lx_mss.common.entity.KafkaTableEntity;
import com.ideal.lx_mss.common.entity.KafkaTopicEntity;
import com.ideal.lx_mss.common.entity.MssKafkaEntity;

import java.util.HashMap;
import java.util.List;
import java.util.concurrent.ExecutionException;

public interface KafkaDataService {
    List<KafkaTopicEntity> getKafkaTopicList();

    List<MssKafkaEntity> selectKafkaList(MssKafkaEntity mssKafkaEntity);

    HashMap<String, Object> pullKafkaDataByTopic(MssKafkaEntity mssKafkaEntity) throws ExecutionException, InterruptedException;

    void mssKafkaDataMark(MssKafkaEntity mssKafkaEntity);

    List<KafkaTopicEntity> allPullKafkaDataByTopic() throws InterruptedException;
}
